<?php
/**
 *Redis 操作类
 *created 2016-03-24
 *@author 江羿平<jyp@cjkt.com>
 *@package Libraries
 */
namespace Libraries;

use Redis;
use ReflectionClass;

class RedisCluster{

    /**
     * 单例对象
     */
    private static $_instance = null;

    /**
     * redis对象
     * @var Redis
     */
	private  $redis;

    /**
     * redis链接设置
     * @var array
     */
    private  $connect_config = array(
            'host'=>REDIS_HOST,
            'port'=>REDIS_PORT,
            'auth_pass'=>REDIS_AUTH
        );

    /**
     * private标记的构造方法，防止被外部new
     */
    private function __construct($param = NULL) {
        $this->connect($param);
    }

    /**
     *创建__clone方法防止对象被复制克隆
     */
    private function __clone(){
        
    }

    /**
     *单例方法,用于访问实例的公共的静态方法
     *@param array $param  连接配置
     *@return RedisCluster
     */
    public static function get_instance($param = NULL){
        if(!(self::$_instance instanceof self)){
            self::$_instance = new self($param);
        }
        return self::$_instance;
    }

    /**
     *连接redis服务器
     *@param array $param redis链接配置
     *@return void
     */
    public function connect($param = NULL){
        $this->redis = new Redis();
        if(!$param){
            $param = $this->connect_config;
        }
        $this->redis->connect($param['host'], $param['port']);
        if($param['auth_pass']){
            $this->redis->auth($param['auth_pass']);
        }
        $this->redis->select(1);
    }

    /**
     *存入一个数组
     * @param string $key KEY名称
     * @param array $arr  设置值
     * @param int $expire 时间  0表示无过期时间
     * @param int $expire_at unix时间戳时间 0表示无过期时间
     * @return bool
     */
    public function set_array($key,$arr,$expire=0,$expire_at=0){
       $value = serialize($arr);
       return $this->set($key,$value,$expire,$expire_at);
    }

    /**
     * 通过key获取数组
     * @param string $key KEY名称
     * @return array|bool
     */
    public function get_array($key){
        $result_string = $this->get($key);
        try {
            $res = unserialize($result_string);
        } catch (Exception $e) {
            $res = array();
        }
        return $res;
    }

    /**
     * 设置值  构建一个字符串
     * @param string $key KEY名称
     * @param string $value  设置值
     * @param int $expire 时间  0表示无过期时间
     * @param int $expire_at unix时间戳时间 0表示无过期时间
     * @return bool
     */
    public function set($key, $value, $expire=0,$expire_at=0) {
        $res = $this->redis->set($key, $value);
        if ($expire > 0) $this->redis->expire($key, $expire);
        else if($expire_at) $this->redis->expire_at($key,$expire_at);
        return $res;
    }

    /**
     * 构建一个集合(无序集合)
     * @param string $key 集合Y名称
     * @param string|array $value  值
     * @return bool
     */
    public function sadd($key,$value){
        return $this->redis->sadd($key,$value);
    }
    
    /**
     * 取集合对应元素
     * @param string $setName 集合名字
     * @return mixed
     */
    public function smembers($setName){
        return $this->redis->smembers($setName);
    }

    /**
     * 构建一个列表(先进后去，类似栈)
     * @param sting $key KEY名称
     * @param string $value 值
     * @return bool
     */
    public function lpush($key,$value){
        return $this->redis->lpush($key,$value);
    }
    
      /**
     * 构建一个列表(先进先去，类似队列)
     * @param sting $key KEY名称
     * @param string $value 值
     * @return bool
     */
    public function rpush($key,$value){
        return $this->redis->rpush($key,$value);
    }

    /**
     * 返回列表key中指定区间内的元素，区间以偏移量start和stop指定
     * @param sting $key KEY名称
     * @param int $head  开始
     * @param int $tail     结束
     * @return List
     */
    public function lranges($key,$head,$tail){
        return $this->redis->lrange($key,$head,$tail);
    }
    
    /**
     * HASH类型
     * @param  string  $tableName  表名字key
     * @param  string  $key        字段名字
     * @param  sting   $value      值
     * @return bool
     */
    public function hset($tableName,$field,$value){
        return $this->redis->hset($tableName,$field,$value);
    }
    /**
     * 批量设置HASH
     * @param string $tableName key
     * @param array $hash 字段数组
     */
    public function hmset($tableName,$hash){
        return $this->redis->hmset($tableName,$hash);
    }

    /**
     * 返回哈希表key中给定域field的值。
     * @param  string  $tableName  表名字key
     * @param  string  $field        字段名字
     * @return string  | nil
     */    
    public function hget($tableName,$field){
        return $this->redis->hget($tableName,$field);
    }
    /**
     * 返回key中给定的hash键值集合
     * @param  string  $tableName  表名字key
     * @param  array  $fields   字段数组
     */
    public function hmget($tableName , $fields){
        if(is_array($fields)){
            return $this->redis->hmget($tableName , $fields);    
        } else {
            return FALSE;
        }
        
    }

    /**
     * 构建一个集合(有序集合)
     * @param string $key 集合名称
     * @param integer|float $score 分数权重
     * @param string|array $member  值
     * @return bool
     */
    public function zadd($key,$score , $member){
        return $this->redis->zadd($key,$score,$member);
    }
    
    /**
     * 返回有序集key中成员member的排名
     * @param  string  $key  表名字key
     * @param string $member 元素名称
     * @return integer
     */
    public function zrevrank($key , $member){
        return $this->redis->zrevrank($key , $member);
    }
    
    /**
     * 设置多个值
     * @param array $keyArray 数据数组（key=>value）
     * @param int   $timeOut  过期时间
     * @return bool
     */
    public function sets($keyArray, $timeout) {
        if (is_array($keyArray)) {
            $retRes = $this->redis->mset($keyArray);
            if ($timeout > 0) {
                foreach ($keyArray as $key => $value) {
                    $this->redis->expire($key, $timeout);
                }
            }
            return $retRes;
        } else {
            return "Call  " . __FUNCTION__ . " method  parameter  Error !";
        }
    }

    /**
     * 通过key获取数据
     * @param string $key KEY名称
     * @return string | nil
     */
    public function get($key) {
        $result = $this->redis->get($key);
        return $result;
    }

    /**
     * 同时获取多个值
     * @param  array $keyArray 获key数值
     * @return array
     */
    public function gets($keyArray) {
        if (is_array($keyArray)) {
            return $this->redis->mget($keyArray);
        } else {
            return "Call  " . __FUNCTION__ . " method  parameter  Error !";
        }
    }

    /**
     * 获取所有key名，不是值
     * @return array
     */
    public function keyAll() {
        return $this->redis->keys('*');
    }

    /**
     * 删除一条数据key
     * @param string $key 删除KEY的名称
     * @return bool
     */
    public function del($key) {
        return $this->redis->delete($key);
    }

    /**
     * 同时删除多个key数据
     * @param array $keyArray KEY集合
     * @return bool
     */
    public function dels($keyArray) {
        if (is_array($keyArray)) {
            return $this->redis->del($keyArray);
        } else {
            return "Call  " . __FUNCTION__ . " method  parameter  Error !";
        }
    }
    
    /**
     * 数据自增
     * @param string $key KEY名称
     * @return bool
     */
    public function increment($key) {
        return $this->redis->incr($key);
    }
    
    /**
     * 数据自减
     * @param string $key KEY名称
     * @return bool
     */
    public function decrement($key) {
        return $this->redis->decr($key);
    }   
    
    /**
     * 判断key是否存在
     * @param string $key KEY名称
     * @return bool
     */
    public function is_exists($key){
        return $this->redis->exists($key);
    }

    /**
     * 重命名- 当且仅当newkey不存在时，将key改为newkey ，当newkey存在时候会报错哦RENAME   
     *  和 rename不一样，它是直接更新（存在的值也会直接更新）
     * @param  string $Key KEY名称
     * @param  string $newKey 新key名称
     * @return bool
     */
    public function updateName($key,$newKey){
        return $this->redis->RENAMENX($key,$newKey);
    }
    
    /**
     * 获取KEY存储的值类型
     * none(key不存在) int(0)  string(字符串) int(1)   list(列表) int(3)  set(集合) int(2)   zset(有序集) int(4)    hash(哈希表) int(5)
     * @param string $key KEY名称
     * @return integer
     */
    public function dataType($key){
        return $this->redis->type($key);
    }
   
    /**
     * 清空数据
     * @return bool
     */
    public function flushAll() {
        return $this->redis->flushAll();
    }
     
    /**
     * 返回redis对象
     * @return Redis
     */
    public function get_redis() {
        return $this->redis;
    }
    /**
     * 设置过期时间
     * @param string $key redis key值
     * @param integer $timeout 过期时长
     */
    public function expire($key , $timeout){
        if(!$this->is_exists($key)){
            throw new Exception("un exist key:{$key}!");
        }
        return $this->redis->expire($key, $timeout);;
    }

    public function __call($name, $arguments)
    {
        $reflect = new ReflectionClass(Redis::Class);
        if ($reflect->hasMethod($name)) {
            return call_user_func_array(array($this->redis, $name), $arguments);
        }

        throw new \BadMethodCallException('call a undefined function '.$name, -1);
    }
} 